module.exports = app => {
	return {
		schedule: {
			cron: app.config.redis_consumption.task_time,
            type: 'worker',
            disable: !(app.config.report_data_type === 'redis'),
		},
		async task(ctx) {
            if (app.config.is_web_task_run || app.config.is_wx_task_run) {
                // 查询db3是否正常,不正常则重启
                try {
					console.log("正在执行定时任务", new Date().getTime())
                    const result = await ctx.model.Ajax.count({}).exec();
                    app.logger.info(`-----------db3--查询db3数据库是否可用----${result}------`);

                    if (app.config.is_web_task_run) ctx.service.wx.monitor.saveWebReportDatasFromRedis();
                    // if (app.config.is_wx_task_run) ctx.service.wx.reportTask.saveWxReportDatasForRedis();
                } catch (err) {
                    app.restartMongodbs('db3', ctx, err);
                }
            }
        },
	}
}